package com.wxf.demo1.listener;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

/**
 * @author: 伍祥丰
 * @date: 2020/3/9 16:15
 * @description：
 */
@Component
public class DemoListener_2 {

    private static final Logger logger = LoggerFactory.getLogger(DemoListener_2.class);

    @KafkaListener(id = "b", topics = "test.abcd.a", groupId = "abcd")
    public void listen(String msgData){
        logger.info("222222 msgData: {}", msgData);
    }

}
